 package srdb.migration.dbhandler.srdb;
 
 
 import java.io.InputStream;
 import java.sql.SQLException;

 import org.srdbsql.SRConnection;
 import org.srdbsql.copy.CopyManager;

import srdb.migration.common.IMTKConnection;
import srdb.migration.common.MTKData;
 
 public class Data extends MTKData
 {
   protected IMTKConnection conn = null;
 
   public Data(IMTKConnection conn, int cpBatchSize)
   {
     this.conn = conn;
     this.dbConn = conn.getConnection();
     if (cpBatchSize != 0)
       MaxBufferSize = 1048576 * cpBatchSize;
   }
 
   public void setTableData(String tableName, InputStream pis, char copyDelimiter)
     throws Exception
   {
     SRConnection copyConn = (SRConnection)this.conn.getConnection();
     CopyManager copy = copyConn.getCopyAPI();
 
     copy.copyIn("COPY " + tableName + " FROM STDIN WITH DELIMITER AS '" + copyDelimiter + "'", pis);
   }
 
   public int setTableDataViaDBLinkOra(String tableName, String targetSchema, String targetTable, boolean truncate) throws SQLException
   {
     throw new UnsupportedOperationException("Not supported yet.");
   }
 }

/* 

 * 
 */